|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
createVolumePermissions to an EBS snapshot.
launchPermissions to an AMI.
productCodes to an AMI.
Project implementation of Logger.AntLoggerHttpFutureCommandClient, Apache Components HttpClient 4.x.ApacheHCHttpCommandExecutorService.BoundedSet object.
ParseSystemAndUserMetadataFromHeaders.
MutableBlobProperties object.
ContainerCDNMetadata object.
<T>.
OpenStackAuthAsyncClient.AuthenticationResponse object.
AccountMetadata object.
MutableObjectInfoWithMetadata object.
org.jclouds.s3.domain.internal.MutableObjectMetadata object.
VCloudSession object.
HttpCommandExecutorService using their fetchAsync callAsyncGaeHttpCommandExecutorService.AtmosBlobStoreContext; requires AtmosAsyncBlobStore bound.AtmosBlobStoreContext or Injector instances based on the most commonly
requested arguments.AtmosObject.ComputeService#runNode operation on the "ec2" provider.AzureBlobStoreContext or Injector instances based on the most commonly
requested arguments.AzureBlob.AzureBlobStoreContext; requires AzureAsyncBlobStore bound.AzureStorageStoreContext or Injector instances based on the most commonly
requested arguments.Base64.InputStream will read data from another
java.io.InputStream, given in the constructor,
and encode/decode to/from Base64 notation on the fly.Base64.InputStream in DECODE mode.
Base64.InputStream in
either ENCODE or DECODE mode.
Base64.OutputStream will write data to another
java.io.OutputStream, given in the constructor,
and encode/decode to/from Base64 notation on the fly.Base64.OutputStream in ENCODE mode.
Base64.OutputStream in
either ENCODE or DECODE mode.
BlobStoreCreateNodesInGroupThenAddToSet requires it
EC2CreateNodesInGroupThenAddToSet is used and is already set-based.
Logger to members annotated with
Resource
This class is a TypeListener so that it can create a logger whose category is
the same as the name of the injected instance's class.AtmosAsyncClient.pathExists(java.lang.String)
AtmosClient.pathExists(java.lang.String)
AzureBlobAsyncClient.blobExists(java.lang.String, java.lang.String)
AzureBlobClient.blobExists(java.lang.String, java.lang.String)
CommonSwiftAsyncClient.objectExists(java.lang.String, java.lang.String)
CommonSwiftClient#blobExists
S3AsyncClient.objectExists(java.lang.String, java.lang.String)
S3Client.objectExists(java.lang.String, java.lang.String)
Blob so that you can manually set metadata such
as length, content-type, or eTag hash.AtmosAsyncClient.headFile(java.lang.String)
AtmosClient.headFile(java.lang.String)
AzureBlobAsyncClient.getBlobProperties(java.lang.String, java.lang.String)
AzureBlobClient.getBlobProperties(java.lang.String, java.lang.String)
Blob at location container/name
Blob.CommonSwiftAsyncClient#headObject
CommonSwiftClient.getObjectInfo(java.lang.String, java.lang.String)
S3AsyncClient.headObject(java.lang.String, java.lang.String)
S3Client.headObject(java.lang.String, java.lang.String)
Blob.BlobStoreContext instances.BlobStoreContexts
BlueLockVCloudComputeServiceContext or Injector instances based on the
most commonly requested arguments.BouncyCastleCryptoPayload#setContentMD5 on the payload.
RunScriptOnNode.init() must be called first.
BaseBlobStore.clearContainer(java.lang.String) then S3Client.deleteBucketIfEmpty(java.lang.String)
until it is true.
BlobStore.clearContainer(String) except you can use options to do things like recursive
deletes, or clear at a different path than root.
BaseAsyncBlobStore.clearContainer(java.lang.String) with the
ListContainerOptions.recursive option.
BlobUtilsImpl.clearContainer(java.lang.String, org.jclouds.blobstore.options.ListContainerOptions)
BaseBlobStore.clearContainer(java.lang.String) with the
ListContainerOptions.recursive option.
BlobUtilsImpl.clearContainer(java.lang.String, org.jclouds.blobstore.options.ListContainerOptions)
BaseAsyncBlobStore.clearContainer(java.lang.String) with the
ListContainerOptions.recursive option.
FilesystemStorageStrategy.clearContainer(String) except you can use options to do things like recursive
deletes, or clear at a different path than root.
HttpResponses
that contain status code 4xx.Writer.
CloudFilesBlobStoreContext or Injector instances based on the most
commonly requested arguments.CloudServersComputeServiceContext; requires BaseComputeService
bound.CloudServersComputeServiceContext; requires BaseComputeService
bound.CloudServersComputeServiceContext or Injector instances based on the most
commonly requested arguments.CloudSigmaClient implementation and the jclouds
ComputeServiceVCloudComputeServiceContext; requires VCloudComputeClientImpl
bound.Futures#compose except that we check the type of the executorService before
creating the Future.
ComputeServices and a concrete compute
cloud implementation, jclouds or otherwise.ComputeServiceContext instances.ComputeServiceContexts
IdentityFunction as that ensure the same value is
returned.
Map<String, ? extends Credentials>HttpCommandExecutorServiceHttpCommandExecutorServiceConsoleLoggerAtmosAsyncClient.pathExists(java.lang.String)
AtmosClient.pathExists(java.lang.String)
AzureBlobAsyncClient.containerExists(java.lang.String)
AzureBlobClient#bucketExists
CommonSwiftAsyncClient.containerExists(java.lang.String)
CommonSwiftClient.containerExists(java.lang.String)
S3AsyncClient.bucketExists(java.lang.String)
S3Client.bucketExists(java.lang.String)
BaseAsyncBlobStore.countBlobs(java.lang.String) with the
ListContainerOptions.recursive option.
BlobUtilsImpl.countBlobs(java.lang.String, org.jclouds.blobstore.options.ListContainerOptions)
BaseBlobStore.countBlobs(java.lang.String) with the
ListContainerOptions.recursive option.
BlobUtilsImpl.countBlobs(java.lang.String, org.jclouds.blobstore.options.ListContainerOptions)
Map view of the specified container.
Map view of the specified container.
AtmosAsyncClient.createDirectory(java.lang.String)
Note location is ignored
AtmosClient.createDirectory(java.lang.String)
AzureBlobAsyncClient.createContainer(java.lang.String, org.jclouds.azureblob.options.CreateContainerOptions...)
AzureBlobClient#putBucketInRegion
CommonSwiftClient#putBucketInRegion
S3AsyncClient.putBucketInRegion(java.lang.String, java.lang.String, org.jclouds.s3.options.PutBucketOptions...)
S3Client.putBucketInRegion(java.lang.String, java.lang.String, org.jclouds.s3.options.PutBucketOptions...)
jclouds.identity failing that
provider.identity where provider corresponds to the parameter.
AtmosAsyncClient.createDirectory(java.lang.String)
AtmosClient.createDirectory(java.lang.String)
BlobUtilsImpl.createDirectory(java.lang.String, java.lang.String)
BlobUtilsImpl.createDirectory(java.lang.String, java.lang.String)
Map view of the specified container.
Map view of the specified container.
ComputeService.createNodesInGroup(String,int,Template), except that the template
is default, equivalent to templateBuilder().any().options(templateOptions).
ComputeService.createNodesInGroup(String,int,TemplateOptions), except that the
options are default, as specified in ComputeService.templateOptions().
ComputeService.runNodesWithTag(String, int, Template) generates the parameters passed
into this method such that each node in the set has a unique name.
ComputeService.runNodesWithTag(String, int, Template) generates the parameters passed
into this method such that each node in the set has a unique name.
ByteStreamsCreateNodesInGroupThenAddToSet requires it
EC2CreateNodesInGroupThenAddToSet is used and is already set-based.
HttpErrorHandlers who are annotated according to the
response codes they relate to.HttpRetryHandlers who are annotated according to the
response codes they relate to.AtmosAsyncClient.deletePath(java.lang.String) followed by
AtmosAsyncClient.pathExists(java.lang.String) until it is true.
AtmosAsyncClient.deletePath(java.lang.String) followed by
AtmosAsyncClient.pathExists(java.lang.String) until it is true.
S3Utils.deleteAndVerifyContainerGone(org.jclouds.s3.S3Client, java.lang.String)
S3Utils.deleteAndVerifyContainerGone(org.jclouds.s3.S3Client, java.lang.String)
S3Client.deleteBucketIfEmpty(java.lang.String) followed by
S3Client.bucketExists(java.lang.String) until it is true.
AzureBlobAsyncClient.deleteContainer(java.lang.String)
AzureBlobClient.deleteContainer(java.lang.String)
BaseAsyncBlobStore.deleteAndEnsurePathGone(java.lang.String)
#deleteAndEnsurePathGone
BaseAsyncBlobStore.deleteAndEnsurePathGone(java.lang.String)
#deleteAndEnsurePathGone
AtmosAsyncBlobStore.removeBlob(java.lang.String, java.lang.String)
AtmosBlobStore.removeBlob(java.lang.String, java.lang.String)
BlobUtilsImpl.deleteDirectory(java.lang.String, java.lang.String).
BlobUtilsImpl.deleteDirectory(java.lang.String, java.lang.String).
BlobPrefix element
in the response body that acts as a placeholder for all blobs whose names begin with the same
substring up to the appearance of the delimiter character.
VCloudClient.deployVAppOrVm(URI), except deploy transistions to power on state
BaseComputeService.destroyNodesMatching(com.google.common.base.Predicate) except that this will clean implicit
keypairs and security groups.
BaseComputeService.destroyNodesMatching(com.google.common.base.Predicate) except that this will clean implicit
keypairs.
AtmosAsyncClient.pathExists(java.lang.String)
AtmosClient.pathExists(java.lang.String)
BlobUtilsImpl.directoryExists(java.lang.String, java.lang.String)
BlobUtilsImpl.directoryExists(java.lang.String, java.lang.String)
DynamicThreadPoolExecutor.ExecutorService that executes each submitted task using one of
possibly several pooled threads, normally configured using
DynamicExecutors factory methods.SynchronousQueue which acts as a rendezvous channel.Integer.MAX_VALUE.
ComputeServiceContext; requires EC2ComputeService bound.EC2ComputeServiceContext or Injector instances based on the most commonly
requested arguments.ComputeService#runNode operation on the "ec2" provider.ElasticStackClient implementation and the jclouds
ComputeServiceObjects implementation as the object count will be
relatively small and therefore efficiency is not a concern.
<R> into value type <T>
<R> into value type <T>
ExecutorService.BlobUtils interfaced and act as a bridge to
FilesystemStorageStrategy when used inside AsyncBlobStoreFOUND_PID if successful.
Writer
and flushes that writer.
Statements.findPid(java.lang.String)
T that is pem encoded in the supplier.
US_STANDARD is returned as "" xml documents.
Iterables dealing with FuturesFuturesHttpCommandExecutorServiceRestContext.getAsyncApi() with predetermined
timeouts.
AtmosAsyncClient.readFile(java.lang.String, org.jclouds.http.options.GetOptions...)
AtmosClient.readFile(java.lang.String, org.jclouds.http.options.GetOptions...)
AzureBlobAsyncClient.getBlob(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)
AzureBlobClient.getBlob(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)
Blob representing the data at location container/name
Blob representing the data at location container/name
AsyncBlobStore.getBlob(String,String,org.jclouds.blobstore.options.GetOptions)
BlobStore.getBlob(String,String,org.jclouds.blobstore.options.GetOptions)
CommonSwiftAsyncClient.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)
CommonSwiftClient.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)
S3AsyncClient.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)
S3Client.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)
a/ and delimiter is set to / then
commonprefixes would return 1,2
a/ and delimiter is set to / then
commonprefixes would return 1,2
Permissions of an snapshot.
id
of the resource with a namespace prefix (ex.
id
of the resource.
File object that links to the blob
File object that links to the blob
BaseAsyncBlobStore.list(String) and retrieve
BucketMetadata.getOwner()
Permissions of an image.
VirtualHardwareSection elements shall
be defined in the NetworkSection.
marker to this value
marker to this value
org.jclouds.compute.ComputeService#runScriptOnNodesWithTag.
VApp or VAppTemplate containing this vm.
VApp or VAppTemplate containing this vm.
RestContext objects.
GaeHttpCommandExecutorService.Objects implementation as the object count will be
relatively small and therefore efficiency is not a concern.
metadata of
the object associated with the key or
org.jclouds.s3.domain.internal.BucketListObjectMetadata#NOT_FOUND if not
available.
HttpCommandExecutorServiceHttpCommandExecutorServiceHttpRequestFilter.filter(org.jclouds.http.HttpRequest) must be idempotent in a sense that multiple calls to it with the same
request yield in the same output.HttpCommandExecutorServiceeTag.
eTag.
eTag.
eTag.
eTag.
eTag.
InputStream implementation that allows chaining of various streams for seamless
sequential readingorg.jclouds.aws.s3.domain.S3Bucket.InputSupplierlf to be portable
HttpCommandExecutorService.JavaUrlHttpCommandExecutorService.Logger implementation of Logger.JDKLoggerJodaDateServiceout.
FOUND_PID if set.
AtmosAsyncClient.listDirectories(org.jclouds.atmos.options.ListOptions...)
AtmosAsyncClient.listDirectory(java.lang.String, org.jclouds.atmos.options.ListOptions...)
AtmosClient.listDirectories(org.jclouds.atmos.options.ListOptions...)
AtmosClient.listDirectory(java.lang.String, org.jclouds.atmos.options.ListOptions...)
AzureBlobAsyncClient.listContainers(org.jclouds.azure.storage.options.ListOptions...) with the
ListOptions.includeMetadata() option.
AzureBlobAsyncClient#listBucket
AzureBlobClient.listContainers(org.jclouds.azure.storage.options.ListOptions...)
AzureBlobClient.listBlobs(java.lang.String, org.jclouds.azureblob.options.ListBlobsOptions...)
BlobStore.list(String) except you can control the size, recursion, and context of the list
using options
AsyncBlobStore.list(String,org.jclouds.blobstore.options.ListContainerOptions)
BlobStore.list(String,org.jclouds.blobstore.options.ListContainerOptions)
CommonSwiftAsyncClient.listContainers(org.jclouds.openstack.swift.options.ListContainerOptions...)
CommonSwiftAsyncClient#listBucket
CommonSwiftClient.listContainers(org.jclouds.openstack.swift.options.ListContainerOptions...)
CommonSwiftClient.listObjects(java.lang.String, org.jclouds.openstack.swift.options.ListContainerOptions...)
S3AsyncClient.listOwnedBuckets()
S3AsyncClient.listBucket(java.lang.String, org.jclouds.s3.options.ListBucketOptions...)
S3Client.listOwnedBuckets()
S3Client.listBucket(java.lang.String, org.jclouds.s3.options.ListBucketOptions...)
ContainerListings provide means to access the underlying Blob.S3Bucket listing.
S3Objects
Every object stored in Amazon S3 is contained in a bucket.withDetails()
withDetails()
withDetails()
LoadBalancerServices
and a concrete compute cloud implementation, jclouds or otherwise.LoadBalancerServiceContext instances.LoadBalancerServiceContexts
Logger implementation of Logger.Log4JLoggerLogger relevant to the specified categoryFutures#makeListenable except that we pass in an executorService.
Maps.MoreExecutorsBlob.Blob.BlobUtilsImpl.newBlob(java.lang.String)
BlobUtilsImpl.newBlob(java.lang.String)
DynamicExecutors.newScalingThreadPool(int, int, long), but blocks the call to execute if the
queue has reached it's capacity, and all max threads are busy handling requests.
DynamicExecutors.newBlockingThreadPool(int, int, long, int, long),
using the provided ThreadFactory to create new threads when needed.
OutputStream to an OutputSupplier
DynamicExecutors.newScalingThreadPool(int, int, long), using the
provided ThreadFactory to create new threads when needed.
NullLoggernull.
HttpCommandExecutorService commands.HttpCommandExecutorService commands.AccountMetadata from HTTP headers.OpenStackAuthAsyncClient.AuthenticationResponse from HTTP headers.BlobProperties from HTTP
headers.AccountMetadata from HTTP headers.AccountMetadata from HTTP headers.org.jclouds.azureblob.domain.ListableContainerProperties from
HTTP headers.BoundedSet from HTTP headers and xml content.error
response from a json string.HttpHeaders.ETAG.ips from a json string.jobs from a json string.jobs from a json
string.VCloudSession from HTTP headers.MapTypeAdapter make a sane object graph when the
value is set to Object
http://code.google.com/p/google-gson/issues/detail?id=325MutableObjectInfoWithMetadata from HTTP headers.ObjectInfo from a gson string.org.jclouds.s3.domain.internal.MutableObjectMetadata from HTTP
headers.Server from a json string.servers from a json string.X509Certificate to PEM format.
PublicKey to PEM format.
PrivateKey to PEM format.
PowerCommand
RSAPrivateKeySpec that is pem encoded in the supplier.
Pems.privateKeySpec(InputSupplier) on the string which contains an encoded
private key in PEM format.
Hardware of a NodeMetadataInternetServiceregionId
.iso3166-codes and jclouds.zone.zoneId.iso3166-codesregionId.endpointregionId.zonesKeySpec that is pem encoded in the supplier.
Pems.publicKeySpec(InputSupplier) on the string which contains an encoded
public key in PEM format.
AtmosAsyncClient.createFile(java.lang.String, org.jclouds.atmos.domain.AtmosObject)
Since there is no etag support in atmos, we just return the path.
AtmosClient.createFile(java.lang.String, org.jclouds.atmos.domain.AtmosObject)
Since there is no etag support in atmos, we just return the path.
AzureBlobAsyncClient.putBlob(java.lang.String, org.jclouds.azureblob.domain.AzureBlob)
AzureBlobClient#putObject
Blob representing the data at location container/blob.metadata.name
CommonSwiftAsyncClient.putObject(java.lang.String, org.jclouds.openstack.swift.domain.SwiftObject)
CommonSwiftClient.putObject(java.lang.String, org.jclouds.openstack.swift.domain.SwiftObject)
S3AsyncClient.putObject(java.lang.String, org.jclouds.s3.domain.S3Object, org.jclouds.s3.options.PutObjectOptions...)
S3Client.putObject(java.lang.String, org.jclouds.s3.domain.S3Object, org.jclouds.s3.options.PutObjectOptions...)
Base64.InputStream.read() repeatedly until the end of stream
is reached or len bytes are read.
HttpResponses that contain status
code 3xx.AtmosAsyncClient.deletePath(java.lang.String)
AtmosClient.deletePath(java.lang.String)
AzureBlobAsyncClient#deleteObject
AzureBlobClient#deleteObject
Blob representing the data at location container/name
CommonSwiftAsyncClient.removeObject(java.lang.String, java.lang.String)
CommonSwiftClient.removeObject(java.lang.String, java.lang.String)
S3AsyncClient.deleteObject(java.lang.String, java.lang.String)
S3Client.deleteObject(java.lang.String, java.lang.String)
createVolumePermissions from an EBS snapshot.
launchPermissions from an AMI.
productCodes from an AMI.
k1, its value will be assigned to the key
k2.
{token}
ex.
{token}
ex.
VAppStatus#OFF -> VAppStatus#ON
createVolumePermissions on an EBS snapshot.
launchPermissions on an AMI.
RestContext or Injector instances based on the most commonly requested
arguments.RestContext instances.RestContext definitions from the specified properties.
suspended state,
given its id.
suspended state,
given its id.
suspendedS3BlobStoreContext; requires S3AsyncBlobStore bound.S3Context or Injector instances based on the most commonly requested
arguments.S3Object.HttpResponses that contain status
code 5xx.ServerManager implementation and the jclouds
ComputeServicedir property is set, this will be copied recursively to the remote
host.
ContentMetadata.HTTP_HEADERS
SimpleDateFormat internally.SlicehostComputeServiceContext; requires BaseComputeService bound.SlicehostComputeServiceContext; requires BaseComputeService bound.SlicehostComputeServiceContext or Injector instances based on the most
commonly requested arguments.PumpStreamHandler for stream handling.
start
VAppStatus#OFF -> deleted
HttpResponse.
Future.get().
Future.get().
suspendedCloudFilesBlobStoreContext; requires SwiftAsyncBlobStore
bound.CloudFilesBlobStoreContext or Injector instances based on the most
commonly requested arguments.SwiftObject.arg.
count bytes of the object
EC2TemplateOptions.
ComputeService#runNodesWithTag operation.EC2TemplateOptions.
TerremarkVCloudTemplateOptions.
TerremarkVCloudComputeServiceContext or Injector instances based on the
most commonly requested arguments.TerremarkVCloudComputeServiceContext; requires
TerremarkVCloudComputeClientImpl bound.TerremarkVCloudComputeServiceContext or Injector instances based on the
most commonly requested arguments.ComputeService#runNode operation on the
"trmk-vcloudexpress" provider.bucketParser is only enacted when the http status code is 2xx.bucketParser is only enacted when the http status code is 2xx.{key}={value}.
Objects implementation as the object count will be
relatively small and therefore efficiency is not a concern.
T from the HttpResponse.EndpointCommand into generic
type EndpointCommand into generic
type EndpointCommand into generic
type BaseAsyncBlobStore which keeps all data in a local Map object.TransientBlobStoreContext; requires TransientAsyncBlobStore bound.VCloudClient.undeployVAppOrVm(URI), where the undeployed virtual machines are suspended and
their suspend state saved
ParamValidators.
Predicate
and ParamValidatorss.value.
value literally
value.
value.
value.
value.
VAppTemplate.VCloudComputeServiceContext; requires VCloudComputeClientImpl
bound.VCloudComputeServiceContext or Injector instances based on the most
commonly requested arguments.VCloudComputeServiceContext; requires
VCloudExpressComputeClientImpl bound.VCloudComputeServiceContext or Injector instances based on the most
commonly requested arguments.ComputeService#runNode operation on the "vcloud"
provider.OperatingSystemorg.apache.HttpWire.impl.conn.WireBase64.OutputStream.write(int) repeatedly until len
bytes are written.
Blob Payload into a file
Blob Payload into a file
X509EncodedKeySpec that is pem encoded in the supplier.
Pems.x509Certificate(InputSupplier, CertificateFactory) on the string which
contains an X.509 certificate in PEM format.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||